package com.atguigu.day09;

import org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend;
import org.apache.flink.runtime.state.hashmap.HashMapStateBackend;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class Flink02_StateBackend {
    public static void main(String[] args) {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();


        //TODO 设置状态后端
        env.setStateBackend(new HashMapStateBackend());

        env.setStateBackend(new EmbeddedRocksDBStateBackend());
    }
}
